0f8d838a7fc93237a0ffbf14f3199cedce6933cd,src/org/jgroups/protocols/pbcast/NAKACK.java,NAKACK,handleXmitReq,#Address#number#number#,510
Before Change
log.trace("received xmit request for " + dest + " [" + first_seqno + " - " + last_seqno + "]");
if(first_seqno > last_seqno) {
if(log.isErrorEnabled())
log.error("first_seqno (" + first_seqno + ") > last_seqno (" + last_seqno + "): not able to retransmit");
return;
}
list=new LinkedList();
for(long i=first_seqno; i <= last_seqno; i++) {
m=(Message)sent_msgs.get(new Long(i)); // no need to synchronized
if(m == null) {
if(log.isErrorEnabled())
log.error("(requester=" + dest + ", local_addr=" + this.local_addr + ") message with " +
"seqno=" + i + " not found in sent_msgs ! sent_msgs=" + printSentMsgs());
continue;
}
len=m.size();
After Change
}
if (first_seqno > last_seqno) {
if (log.isErrorEnabled()) {
log.error(
"first_seqno (" + first_seqno + ") > last_seqno (" + last_seqno + "): not able to retransmit");
}
return;
}
list = new LinkedList();
for (long i = first_seqno; i <= last_seqno; i++) {
m = (Message) sent_msgs.get(new Long(i)); // no need to synchronized
if (m == null) {
if (log.isErrorEnabled()) {
log.error(
"(requester=" + dest + ", local_addr=" + this.local_addr + ") message with " +
"seqno=" + i +
" not found in sent_msgs ! sent_msgs=" +
printSentMsgs());
}
continue;
}